package com.doit.spark.day04

import com.doit.spark.day01.utils.SparkUtil

/**
 * @DATE 2022/1/6/22:12
 * @Author MDK
 * @Version 2021.2.2
 * */
object C02_分布式闭包_检测 {
  def main(args: Array[String]): Unit = {
    val sc = SparkUtil.getSc
    val list = List[(Int, String, Int)]((1, "袜子", 88), (2, "裤子", 99), (3, "帽子", 66), (4, "褂子", 199))
    val rdd = sc.makeRDD(list, 2)
    val f=(e:(Int, String, Int)) =>{
      e
    }
    rdd.map(f)
  }
}
